package com.bjsxt.height.concurrent018;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;


/**
 * <a href="https://www.cnblogs.com/jiangxiulian/p/7443983.html">ThreadPool参数设置简介: 推荐 </a>
 * <a href="https://blog.csdn.net/qq_25806863/article/details/71126867">ThreadPoolExecutor Blog</a>
 * <p>
 * ThreadPoolExecutor参数: 先用corePoolSize的, corePool满了则丢到Queue, Queue满了则继续申请新Thread直至顶到maxPoolSize, 才拒绝
 */
public class UseThreadPoolExecutor1 {

    public static void main(String[] args) {
        /**
         * 在使用有界队列时，若有新的任务需要执行，如果线程池实际线程数小于corePoolSize，则优先创建线程，
         * 若大于corePoolSize，则会将任务加入队列，
         * 若队列已满，则在总线程数不大于maximumPoolSize的前提下，创建新的线程，
         * 若线程数大于maximumPoolSize，则执行拒绝策略。或其他自定义方式。
         */
        ThreadPoolExecutor pool = new ThreadPoolExecutor(
                1,                // coreSize
                2,            // MaxSize
                60,                // 非核心线程的闲置超时时间，超过这个时间就会被回收
                TimeUnit.SECONDS,
                new ArrayBlockingQueue<Runnable>(3)            //指定一种队列 （有界队列）
                //new LinkedBlockingQueue<Runnable>()
                , new MyRejected()                // 添加任务被拒时自动执行
                //, new DiscardOldestPolicy()
        );

        MyTask mt1 = new MyTask(1, "任务1");
        MyTask mt2 = new MyTask(2, "任务2");
        MyTask mt3 = new MyTask(3, "任务3");
        MyTask mt4 = new MyTask(4, "任务4");
        MyTask mt5 = new MyTask(5, "任务5");
        MyTask mt6 = new MyTask(6, "任务6");

        pool.execute(mt1);
        pool.execute(mt2);
        pool.execute(mt3);
        pool.execute(mt4);
        pool.execute(mt5);
        pool.execute(mt6);

        pool.shutdown();

    }
}
